home *** CD-ROM | disk | FTP | other *** search
/ Aminet 19 / Aminet 19 (1997)(GTI - Schatztruhe)[!][Jun 1997].iso / Aminet / comm / net / ARemote1_00B.lha / ARemote / source / divert.c < prev    next >
C/C++ Source or Header  |  1997-04-27  |  24KB  |  785 lines
  1. #include <string.h>
  2. #include <stdarg.h>
  3. #include <exec/libraries.h>
  4. #include <exec/memory.h>
  5. #include <libraries/commodities.h>
  6. #include <libraries/gadtools.h>
  7. #include <intuition/gadgetclass.h>
  8. #include <dos/dos.h>
  9. #include <clib/exec_protos.h>
  10. #include <clib/alib_protos.h>
  11. #include <clib/alib_stdio_protos.h>
  12. #include <clib/commodities_protos.h>
  13. #include <intuition/intuition.h>
  14. #include <devices/inputevent.h>
  15. #include <clib/AMarquee_protos.h>
  16. #include <pragmas/AMarquee_pragmas.h>
  17. #include <exec/types.h>
  18. #include <hardware/cia.h>
  19.  
  20. #include "ARemote_temp_aux.h"
  21.  
  22. #define CIAA 0xBFE001
  23.  
  24. #define AREMOTE_NAME "ARemote v1.00B"
  25.  
  26. const char version[] = "$VER: ARemote 1.00B";
  27.  
  28. #define DEFAULT_AREMOTE_PASSWORD  "ARemote"
  29. #define DEFAULT_AREMOTE_PORT      20000
  30. #define DEFAULT_AREMOTE_TOGGLEKEY "lcommand shift x"
  31. #define DEFAULT_AREMOTE_POPKEY    "lcommand y"
  32.  
  33. #define EVENT_TOGGLEKEY  1
  34. #define EVENT_SHOWWINDOW 2
  35.  
  36. #define UNLESS(x) if(!(x))
  37.  
  38. int main(int, char **);
  39. void ProcessMsg(struct MsgPort * broker_mp);
  40. void CxFunction(CxMsg *, CxObj *);
  41.  
  42. char * connectTo = NULL;
  43. int connectToPort;
  44. char * connectToPassword = NULL;
  45. char * acceptFrom  = NULL;
  46. int acceptFromPort;
  47. char * acceptFromPassword = NULL;
  48. BOOL BConnectOnStartup;
  49. BOOL BXmitCue;
  50. char * toggleKey = NULL;
  51. char * popKey = NULL;
  52.  
  53. /* Internal state info */
  54. BOOL BEnabled              = TRUE;
  55. BOOL BConnectOkay          = FALSE; 
  56. BOOL BWindowOpen           = FALSE;
  57. BOOL BGUINeedsUpdate       = FALSE;
  58. BOOL BSessionIsHostSession = FALSE;
  59. BOOL BXmitting             = FALSE;  /* True iff we are diverting all input to the TCP stream */
  60. BOOL BStartedFromWB        = FALSE;
  61.  
  62. struct QSession * session     = NULL;
  63. struct Library * AMarqueeBase = NULL, * CxBase        = NULL, * IconBase = NULL,
  64.                * GadToolsBase = NULL, * GfxBase  = NULL,
  65.                * UtilityBase  = NULL, * DiskFontBase  = NULL;
  66. struct Task * mainTask;
  67.  
  68. struct MsgPort * event_mp;
  69. CxObj * cxBroker = NULL, * cxFilter = NULL, * cxCustom = NULL, * cxSender = NULL, * cxDrain1 = NULL, * cxDrain2 = NULL, * cxPopFilter = NULL, * cxPopSender = NULL, * cxPopDrain = NULL;
  70.  
  71. ULONG winRequests;
  72.  
  73. struct NewBroker newbroker =
  74. { 
  75.   NB_VERSION,
  76.   "ARemote",
  77.   "ARemote",
  78.   "Remote-control your Amiga",
  79.   NBU_UNIQUE | NBU_NOTIFY,
  80.   COF_SHOW_HIDE, 0, 0, 0
  81. };
  82.  
  83. int MakeReq(char *sTitle, char *sText, char *sGadgets)
  84. {
  85.     struct EasyStruct myreq;
  86.     int nResult;
  87.  
  88.     UNLESS(sTitle)   sTitle   = "ARemote Message";
  89.     UNLESS(sText)    sText    = "Check this out!";
  90.     UNLESS(sGadgets) sGadgets = "OK";
  91.  
  92.     myreq.es_TextFormat   = sText;
  93.     myreq.es_Title        = sTitle;
  94.     myreq.es_GadgetFormat = sGadgets;
  95.  
  96.     if (IntuitionBase) nResult = EasyRequest(NULL, &myreq, NULL, NULL, NULL);
  97.                   else printf("Notice: [%s] [%s]\n",sTitle, sText);
  98.        
  99.     return(nResult);
  100. }
  101.  
  102.  
  103. /* does dynamic allocating and freeing of char strings */
  104. /* The old value will not be freed unless a new one could be allocated. */
  105. /* (or no new value was requested) */
  106. char * SetString(char * oldString, char * newVal)
  107. {
  108.   char * newString;
  109.     
  110.   if (newVal)
  111.   {
  112.     if (newString = AllocVec(strlen(newVal)+1, MEMF_ANY))
  113.     {
  114.       strcpy(newString, newVal);
  115.       if (oldString) FreeVec(oldString);
  116.       return(newString);
  117.     }
  118.     else 
  119.     {
  120.       DisplayBeep(NULL);
  121.       return(oldString);
  122.     }
  123.   }
  124.   else if (oldString) FreeVec(oldString);
  125.   
  126.   return(NULL);
  127. }
  128.  
  129. void StatMsg(char * msg)
  130. {
  131.   static char retain[200] = "ARemote Ready.";
  132.   
  133.   if (msg) strncpy(retain, msg, sizeof(retain));
  134.   if (BWindowOpen) SetWindowTitles(ARemoteWnd, retain, (char *)~0);
  135. }
  136.  
  137. /* Makes pcString lower case */
  138. char * ToLower(char * pcString)
  139. {
  140.     char * pcTemp = pcString;
  141.     
  142.     while(*pcTemp) 
  143.     {
  144.         if ((*pcTemp >= 'A')&&(*pcTemp <= 'Z'))
  145.             *pcTemp += 'a'-'A';
  146.         pcTemp++;
  147.     }
  148.     return(pcString);
  149. }
  150.  
  151. void edebug(int i)
  152. {
  153.   int a = *((int *)i);
  154. }
  155.  
  156. #define UPDATEMENUFLAG(item, variable, flag) {if (variable) item->Flags |= flag; else item->Flags &= ~(flag);}
  157. void UpdateGUIFromState(void)
  158. {
  159.   if (BWindowOpen)
  160.   {
  161.     struct Menu *currentMenu = ARemoteMenus;  /* Project Menu */
  162.     struct MenuItem *currentItem;
  163.  
  164.     /* Go through all gadgets and menu items, set them to the correct state */
  165.     GT_SetGadgetAttrs(ARemoteGadgets[GD_ConnectToString],   ARemoteWnd, NULL, GTST_String, connectTo,      TAG_END);
  166.     GT_SetGadgetAttrs(ARemoteGadgets[GD_AcceptFromString],  ARemoteWnd, NULL, GTST_String, acceptFrom,     TAG_END);
  167.     GT_SetGadgetAttrs(ARemoteGadgets[GD_ConnectToPortInt],  ARemoteWnd, NULL, GTIN_Number, connectToPort,  TAG_END);
  168.     GT_SetGadgetAttrs(ARemoteGadgets[GD_AcceptFromPortInt], ARemoteWnd, NULL, GTIN_Number, acceptFromPort, TAG_END);
  169.     GT_SetGadgetAttrs(ARemoteGadgets[GD_ToggleString],      ARemoteWnd, NULL, GTST_String, toggleKey,      TAG_END);
  170.     GT_SetGadgetAttrs(ARemoteGadgets[GD_ConnectToPasswordString],  ARemoteWnd, NULL, GTST_String, connectToPassword,  TAG_END);
  171.     GT_SetGadgetAttrs(ARemoteGadgets[GD_AcceptFromPasswordString], ARemoteWnd, NULL, GTST_String, acceptFromPassword, TAG_END);
  172.     GT_SetGadgetAttrs(ARemoteGadgets[GD_ConnectOnStartupCheckbox], ARemoteWnd, NULL, GTCB_Checked, BConnectOnStartup, TAG_END);
  173.     GT_SetGadgetAttrs(ARemoteGadgets[GD_ConnectButton],    ARemoteWnd, NULL, GA_Disabled, BConnectOkay, TAG_END);
  174.     GT_SetGadgetAttrs(ARemoteGadgets[GD_DisconnectButton], ARemoteWnd, NULL, GA_Disabled, !BConnectOkay, TAG_END);
  175.     GT_SetGadgetAttrs(ARemoteGadgets[GD_XmitCueCheckbox],  ARemoteWnd, NULL, GTCB_Checked, BXmitCue, TAG_END);
  176.     GT_SetGadgetAttrs(ARemoteGadgets[GD_PopupHotkeyString],ARemoteWnd, NULL, GTST_String, popKey, TAG_END);
  177.     
  178.     ClearMenuStrip(ARemoteWnd);
  179.      currentItem = currentMenu->FirstItem;  /* About... */
  180.      currentItem = currentItem->NextItem;  /* Bar */
  181.      currentItem = currentItem->NextItem;  /* Enabled */
  182.      UPDATEMENUFLAG(currentItem, BEnabled, CHECKED);
  183.  
  184.      currentItem = currentItem->NextItem;   /* Save Settings */
  185.      UPDATEMENUFLAG(currentItem, FALSE, ITEMENABLED);
  186.     ResetMenuStrip(ARemoteWnd, ARemoteMenus);
  187.   }
  188.   BGUINeedsUpdate = FALSE;
  189. }
  190.  
  191. /* return TRUE iff the string represents the boolean value true */
  192. BOOL ParseBool(char * string)
  193. {
  194.   char temp[100];
  195.   
  196.   strncpy(temp,string,sizeof(temp));
  197.   temp[99]=0;
  198.   
  199.   ToLower(temp);
  200.   
  201.   return(
  202.     (*temp=='\0')              ||  /* then it's just KEYWORD, so yes, right? */
  203.     (strcmp("true",temp) == 0) ||
  204.     (strcmp("yes",temp)  == 0) ||
  205.     (strcmp("1",temp)    == 0));   /* Anyone who specifies 1 for true is a weenie! */
  206. }
  207.  
  208. void StartTransmitting(void)
  209. {
  210.   if (BXmitting) return;  /* we're already there */
  211.   
  212.   if (BConnectOkay) 
  213.   {
  214.     char szTemp[300];
  215.     
  216.     strcpy(szTemp, "[");
  217.     strncat(szTemp, toggleKey, sizeof(szTemp));
  218.     strncat(szTemp, "] to stop.", sizeof(szTemp));
  219.     StatMsg(szTemp);
  220.     
  221.     AttachCxObj(cxBroker, cxCustom);
  222.     AttachCxObj(cxBroker, cxDrain1);
  223.     BXmitting = TRUE;
  224.   }
  225.   else
  226.   {
  227.     DisplayBeep(NULL);
  228.     StatMsg("Can't transmit: not connected!");
  229.   }
  230. }
  231.  
  232. void StopTransmitting(void)
  233. {
  234.   if (BXmitting) 
  235.   {
  236.     StatMsg("Transmission stopped.");
  237.     RemoveCxObj(cxCustom);
  238.     RemoveCxObj(cxDrain1);
  239.   }
  240.   BXmitting = FALSE;
  241. }
  242.  
  243. void DoCloseWindow(void)
  244. {
  245.   if (BWindowOpen) 
  246.   {
  247.     CloseARemoteWindow(); 
  248.     BWindowOpen = FALSE;
  249.   } 
  250. }
  251.  
  252. void Disconnect(void)
  253. {
  254.   StopTransmitting();
  255.   if (session) 
  256.   {
  257.     QFreeSession(session);
  258.     if ((BSessionIsHostSession==FALSE)||(BConnectOkay))
  259.       StatMsg(BConnectOkay ? "Connection closed." : "Couldn't connect.");
  260.   }
  261.   session = NULL;
  262.   BConnectOkay = FALSE;
  263.   BGUINeedsUpdate = TRUE;
  264. }
  265.  
  266.  
  267. void Accept(void)
  268. {
  269.   int port = acceptFromPort;
  270.     
  271.   Disconnect();
  272.   session = QNewHostSession(acceptFrom, &port, acceptFromPassword);
  273.   BSessionIsHostSession = TRUE;
  274. }
  275.  
  276. void DoOpenWindow(void)
  277. {
  278.   if (BWindowOpen == FALSE)
  279.   {
  280.     int error;
  281.  
  282.     if (error = OpenARemoteWindow())
  283.     {
  284.       printf("Window open failed, error %i\n",error);
  285.       CloseARemoteWindow();
  286.     }
  287.     else 
  288.     {
  289.       BWindowOpen = TRUE;
  290.       UpdateGUIFromState();
  291.       StatMsg(NULL);
  292.     }
  293.   }
  294. }
  295.  
  296. void EnableCommodity(void)
  297. {
  298.   ActivateCxObj(cxBroker, 1L);
  299.   BEnabled = TRUE;
  300.   BGUINeedsUpdate = TRUE;
  301. }
  302.  
  303. void DisableCommodity(void)
  304. {
  305.   ActivateCxObj(cxBroker, 0L);
  306.   BEnabled = FALSE;
  307.   BGUINeedsUpdate = TRUE;
  308. }
  309.  
  310.  
  311. void ShowAboutBox(void)
  312. {
  313.   MakeReq(NULL, AREMOTE_NAME"\nby Jeremy Friesner\njfriesne@ucsd.edu\nCompiled: "__DATE__,"Yowza");
  314. }
  315.  
  316. void UpdateStateFromGUI(void)
  317. {  
  318.   if (BWindowOpen)
  319.   {
  320.     connectTo          = SetString(connectTo, GetString(ARemoteGadgets[GD_ConnectToString]));
  321.     acceptFrom         = SetString(acceptFrom, GetString(ARemoteGadgets[GD_AcceptFromString]));
  322.     toggleKey          = SetString(toggleKey, GetString(ARemoteGadgets[GD_ToggleString]));
  323.     connectToPassword  = SetString(connectToPassword, GetString(ARemoteGadgets[GD_ConnectToPasswordString]));
  324.     acceptFromPassword = SetString(acceptFromPassword, GetString(ARemoteGadgets[GD_AcceptFromPasswordString]));
  325.     popKey             = SetString(popKey, GetString(ARemoteGadgets[GD_PopupHotkeyString]));
  326.  
  327.     connectToPort     = GetNumber(ARemoteGadgets[GD_ConnectToPortInt]);
  328.     acceptFromPort    = GetNumber(ARemoteGadgets[GD_AcceptFromPortInt]);
  329.     BConnectOnStartup = (((ARemoteGadgets[GD_ConnectOnStartupCheckbox]->Flags)&GFLG_SELECTED) != 0);
  330.     BXmitCue          = (((ARemoteGadgets[GD_XmitCueCheckbox]->Flags)&GFLG_SELECTED) != 0);
  331.   }
  332. }
  333.  
  334. void DoChangeAccept(void)
  335. {
  336.   /* Only make a new host session if we have no session, or we have an unconnected host session */
  337.   if ((session == NULL)||((BSessionIsHostSession)&&(BConnectOkay == FALSE))) Accept();
  338. }
  339.  
  340.  
  341. /* Returns library name on failure, NULL on success */
  342. char * OpenAllLibraries(struct Library ** setLibPtr, char * libName, ULONG libVersion, ...)
  343. {
  344.   va_list vlist;
  345.   BOOL BFirst = TRUE;
  346.     
  347.   va_start(vlist, setLibPtr);
  348.   while((BFirst)||(setLibPtr = va_arg(vlist, struct Library **)))
  349.   {
  350.     libName    = va_arg(vlist, char *);
  351.     libVersion = va_arg(vlist, ULONG);
  352.     UNLESS(*setLibPtr = OpenLibrary(libName, libVersion)) return(libName);
  353.     BFirst = FALSE;
  354.   }
  355.   va_end(vlist);
  356.   return(NULL);
  357. }
  358.  
  359. void CloseAllLibraries(struct Library ** closeLib, ...)
  360. {
  361.   va_list vlist;
  362.   
  363.   if (closeLib == NULL) return;
  364.   if (*closeLib) 
  365.   {
  366.     CloseLibrary(*closeLib);
  367.     *closeLib = NULL;
  368.   }
  369.   
  370.   va_start(vlist, closeLib);
  371.   while(closeLib = va_arg(vlist, struct Library **)) 
  372.   {
  373.     if (*closeLib) 
  374.     {
  375.       CloseLibrary(*closeLib);
  376.       *closeLib = NULL;
  377.     }
  378.   }
  379.   va_end(vlist);
  380. }
  381.  
  382. /* Allocates default strings, does default settings */
  383. BOOL CreateDefaultState(UBYTE ** ttypes)
  384. {
  385.   UNLESS((connectTo          = SetString(NULL, ArgString(ttypes, "CONNECTTO", ""))) &&
  386.          (connectToPassword  = SetString(NULL, ArgString(ttypes, "CONNECTTOPASSWORD", DEFAULT_AREMOTE_PASSWORD))) &&
  387.          (acceptFrom         = SetString(NULL, ArgString(ttypes, "ACCEPTFROM", ""))) &&
  388.          (acceptFromPassword = SetString(NULL, ArgString(ttypes, "ACCEPTFROMPASSWORD", DEFAULT_AREMOTE_PASSWORD))) &&
  389.          (toggleKey          = SetString(NULL, ArgString(ttypes, "TOGGLEKEY", DEFAULT_AREMOTE_TOGGLEKEY))) && 
  390.          (popKey             = SetString(NULL, ArgString(ttypes, "CX_POPKEY", DEFAULT_AREMOTE_POPKEY)))) return(FALSE);
  391.  
  392.   BXmitCue = ParseBool(ArgString(ttypes, "FLASHLED", "FALSE"));
  393.   BConnectOnStartup = ParseBool(ArgString(ttypes, "CONNECTONSTARTUP", "FALSE"));
  394.   connectToPort  = ArgInt(ttypes, "CONNECTTOPORT", DEFAULT_AREMOTE_PORT);
  395.   acceptFromPort = ArgInt(ttypes, "ACCEPTFROMPORT", DEFAULT_AREMOTE_PORT);
  396.     
  397.   /* disable myself? */
  398.   if (ParseBool(ArgString(ttypes, "ENABLED", "TRUE")) == FALSE) Signal(FindTask(NULL), SIGBREAKF_CTRL_D);
  399.   
  400.   /* open window? */
  401.   if (ParseBool(ArgString(ttypes, "CX_POPUP", "TRUE"))) Signal(FindTask(NULL), SIGBREAKF_CTRL_F);
  402.   
  403.   return(TRUE);
  404. }
  405.  
  406. /* Frees all setting strings */
  407. void FreeState()
  408. {
  409.   connectTo          = SetString(connectTo,          NULL);
  410.   connectToPassword  = SetString(connectToPassword,  NULL);
  411.   acceptFrom         = SetString(acceptFrom,         NULL);
  412.   acceptFromPassword = SetString(acceptFromPassword, NULL);
  413.   toggleKey          = SetString(toggleKey,          NULL);
  414.   popKey             = SetString(popKey,             NULL);
  415. }
  416.  
  417. void wbmain(struct WBStartup *wbargv)
  418. {    
  419.   BStartedFromWB = TRUE;
  420.   main(0,wbargv);
  421. }
  422.  
  423. int main(int argc, char ** argv)
  424. {
  425.   UBYTE ** ttypes;
  426.   CxMsg * msg;
  427.   char * errorLib;
  428.     
  429.   mainTask = FindTask(NULL);
  430.  
  431.   if ((BStartedFromWB == FALSE)&&(argc>=2)&&(*argv[1]=='?'))
  432.   {
  433.     printf("Usage: ARemote CONNECTTO/K,CONNECTTOPASSWORD/K,CONNECTTOPORT/K/N,\n"
  434.            "               ACCEPTFROM/K,ACCEPTFROMPASSWORD/K,ACCEPTFROMPORT/K/N,\n"
  435.            "               TOGGLEKEY/K,CX_POPKEY/K,CX_POPUP/K,CX_PRIORITY/K/N\n"
  436.            "               FLASHLED/K,CONNECTONSTARTUP/K,ENABLED/K,ALLOWMULTIPLE/K\n");
  437.     exit(5);
  438.   }  
  439.  
  440.   if (errorLib = OpenAllLibraries(
  441.    &AMarqueeBase,  "amarquee.library",    43L,
  442.    &CxBase,        "commodities.library", 37L,
  443.    &IconBase,      "icon.library",        36L,
  444.    &GadToolsBase,  "gadtools.library",    37L,
  445.    &IntuitionBase, "intuition.library",   37L,
  446.    &GfxBase,       "graphics.library",    37L,
  447.    &UtilityBase,   "utility.library",     37L,
  448.    &DiskFontBase,  "diskfont.library",    38L,  NULL))
  449.   {
  450.     char temp[300];
  451.     
  452.     sprintf(temp, "Error: Couldn't open library [%s]",errorLib);
  453.     MakeReq(NULL,temp,NULL);
  454.   }
  455.   else
  456.   {
  457.     struct MsgPort * broker_mp;
  458.  
  459.     if (SetupScreen()) MakeReq(NULL, "Couldn't lock screen!", NULL);
  460.     else
  461.     {
  462.       int got_to = 0;
  463.       
  464.       if (event_mp = CreateMsgPort())
  465.       {
  466.         got_to = 1;
  467.         
  468.         if (broker_mp = CreateMsgPort())
  469.         { 
  470.           got_to = 2;
  471.           newbroker.nb_Port = broker_mp;
  472.         
  473.           ttypes = ArgArrayInit(argc, argv);
  474.           newbroker.nb_Pri = (BYTE) ArgInt(ttypes, "CX_PRIORITY", 127);
  475.           if (ParseBool(ArgString(ttypes, "ALLOWMULTIPLE", "FALSE"))) newbroker.nb_Unique &= ~(NBU_UNIQUE);
  476.           
  477.           if (CreateDefaultState(ttypes))
  478.           {
  479.             got_to = 3;
  480.             if ((cxPopFilter = CxFilter(popKey))                  &&
  481.                 (cxPopSender = CxSender(broker_mp, EVENT_SHOWWINDOW)) &&
  482.                 (cxPopDrain  = CxTranslate(NULL))                 &&
  483.                 (cxFilter = CxFilter(toggleKey))                  &&
  484.                 (cxSender = CxSender(broker_mp, EVENT_TOGGLEKEY)) &&
  485.                 (cxCustom = CxCustom(CxFunction, 0L))             &&
  486.                 (cxDrain1 = CxTranslate(NULL))                    &&
  487.                 (cxDrain2 = CxTranslate(NULL))                    &&
  488.                 (cxBroker = CxBroker(&newbroker, NULL)))
  489.             {
  490.               got_to = 4;
  491.               /* Catch the cx_popup hotkey */
  492.               AttachCxObj(cxBroker,    cxPopFilter);
  493.               AttachCxObj(cxPopFilter, cxPopSender);
  494.               AttachCxObj(cxPopFilter, cxPopDrain);
  495.               
  496.               /* Catch the toggle hotkey */
  497.               AttachCxObj(cxBroker, cxFilter);
  498.               AttachCxObj(cxFilter, cxSender);
  499.               AttachCxObj(cxFilter, cxDrain2);
  500.  
  501.               ActivateCxObj(cxBroker, 1L);
  502.  
  503.               ProcessMsg(broker_mp);
  504.             }
  505.  
  506.             /* Clean up */
  507.             if (cxPopFilter) DeleteCxObj(cxPopFilter);
  508.             if (cxPopSender) DeleteCxObj(cxPopSender);
  509.             if (cxPopDrain)  DeleteCxObj(cxPopDrain);
  510.             if (cxDrain1) DeleteCxObj(cxDrain1);
  511.             if (cxDrain2) DeleteCxObj(cxDrain2);
  512.             if (cxCustom) DeleteCxObj(cxCustom);
  513.             if (cxSender) DeleteCxObj(cxSender);
  514.             if (cxFilter) DeleteCxObj(cxFilter);
  515.             if (cxBroker) DeleteCxObj(cxBroker);
  516.             while(msg = (CxMsg *) GetMsg(broker_mp)) ReplyMsg((struct Message *)msg);
  517.           }
  518.           FreeState();
  519.           DeletePort(broker_mp);
  520.         }
  521.          
  522.         while(msg = (CxMsg *) GetMsg(event_mp)) FreeMem(msg, ((struct Message *)msg)->mn_Length);
  523.         DeletePort(event_mp);
  524.       }
  525.       ArgArrayDone();
  526.       
  527.       if (got_to != 4) 
  528.       {
  529.         char temp[300];
  530.         
  531.         sprintf(temp, "Error setting up in stage %i", got_to);
  532.         MakeReq(NULL, temp, NULL);
  533.       }
  534.     }
  535.     DoCloseWindow();
  536.     CloseDownScreen();  /* must be called even if SetupScreen() failed */
  537.   }
  538.   CloseAllLibraries(&AMarqueeBase, &CxBase, &IconBase, &GadToolsBase,
  539.                     &IntuitionBase, &GfxBase, &UtilityBase, &DiskFontBase, NULL);
  540.   return(0);
  541. }
  542.  
  543.  
  544. void Connect(void)
  545. {  
  546.   char temp[300];
  547.   
  548.   Disconnect();
  549.   session = QNewSessionAsync(connectTo, connectToPort, connectToPassword);
  550.   BSessionIsHostSession = FALSE;
  551.   
  552.   if (session)
  553.   {
  554.     strcpy(temp, "Connecting: [");
  555.     strncat(temp, connectTo, sizeof(temp));
  556.     strncat(temp, "]", sizeof(temp));
  557.     StatMsg(temp);
  558.   }
  559.   else StatMsg("Can't make connection.");
  560. }
  561.  
  562. void ChangeToggle(void)
  563. {
  564.   CxObj * newFilter;
  565.  
  566.   if (newFilter = CxFilter(toggleKey))
  567.   {
  568.     DeleteCxObj(cxFilter);
  569.     cxFilter = newFilter;
  570.     
  571.     AttachCxObj(cxFilter, cxSender);
  572.     AttachCxObj(cxFilter, cxDrain2);
  573.     AttachCxObj(cxBroker, cxFilter);    
  574.   }
  575.   else DisplayBeep(NULL);
  576. }
  577.  
  578. void ChangePopup(void)
  579. {
  580.   CxObj * newFilter;
  581.  
  582.   if (newFilter = CxFilter(popKey))
  583.   {
  584.     DeleteCxObj(cxPopFilter);
  585.     cxPopFilter = newFilter;
  586.     
  587.     AttachCxObj(cxPopFilter, cxPopSender);
  588.     AttachCxObj(cxPopFilter, cxPopDrain);
  589.     AttachCxObj(cxBroker, cxPopFilter);    
  590.   }
  591.   else DisplayBeep(NULL);
  592. }
  593.  
  594. void ToggleLED(void)
  595. {
  596.   static BOOL Bright = TRUE;
  597.   static struct CIA *cia = (struct CIA *) CIAA;
  598.   
  599.   Bright = !Bright;
  600.   
  601.   if (Bright) cia->ciapra |= CIAF_LED; else cia->ciapra &= ~(CIAF_LED);
  602. }
  603.  
  604.  
  605. void ProcessMsg(struct MsgPort * broker_mp)
  606. {
  607.   struct Message * msg;
  608.   CxMsg * cmsg;
  609.   ULONG sigrcvd;
  610.   BOOL keepGoing = TRUE;
  611.  
  612.   if (BConnectOnStartup) Connect(); else Accept();
  613.        
  614.   while(keepGoing)
  615.   {
  616.     sigrcvd = Wait((BWindowOpen ? (1L<<ARemoteWnd->UserPort->mp_SigBit) : 0L) | SIGBREAKF_CTRL_C | SIGBREAKF_CTRL_D | SIGBREAKF_CTRL_E | SIGBREAKF_CTRL_F | (1L<<broker_mp->mp_SigBit) | (1L<<event_mp->mp_SigBit) | (session ? (1L<<session->qMsgPort->mp_SigBit) : 0L));
  617.     
  618.     if ((BWindowOpen)&&(sigrcvd & (1L<<ARemoteWnd->UserPort->mp_SigBit))) 
  619.     {
  620.       winRequests = 0L;
  621.       
  622.       HandleARemoteIDCMP();
  623.       
  624.       /* Check to see if HandleARemoteIDCMP() wanted the window open or closed */
  625.       if (winRequests & FLAG_UPDATE_STATE)  UpdateStateFromGUI();
  626.       if (winRequests & FLAG_CHANGE_ACCEPT) DoChangeAccept();
  627.       if (winRequests & FLAG_ABOUT)         ShowAboutBox();
  628.       if (winRequests & FLAG_CLOSE_WINDOW)  DoCloseWindow();
  629.       if (winRequests & FLAG_DISCONNECT)    Accept();
  630.       if (winRequests & FLAG_CONNECT)       Connect();
  631.       if (winRequests & FLAG_DISABLE)       DisableCommodity();
  632.       if (winRequests & FLAG_ENABLE)        EnableCommodity();
  633.       if (winRequests & FLAG_CHANGE_TOGGLE) ChangeToggle();
  634.       if (winRequests & FLAG_CHANGE_POPUP)  ChangePopup();
  635.       if (winRequests & FLAG_QUIT)          keepGoing = FALSE;
  636.     }
  637.     
  638.     while(cmsg = (CxMsg *)GetMsg(broker_mp))
  639.     {
  640.       ULONG msgid, msgtype;
  641.       
  642.       msgid = CxMsgID(cmsg);
  643.       msgtype = CxMsgType(cmsg);
  644.       
  645.       ReplyMsg((struct Message *)cmsg);
  646.  
  647.       switch(msgtype)
  648.       {
  649.         case CXM_IEVENT:
  650.           switch(msgid)
  651.           {
  652.             case EVENT_TOGGLEKEY:
  653.               if (BXmitting) StopTransmitting(); else StartTransmitting();
  654.             break;
  655.             
  656.             case EVENT_SHOWWINDOW:
  657.               DoOpenWindow();
  658.               break;
  659.               
  660.             default:
  661.               printf("Unknown event %i?\n",msgid);
  662.               break;
  663.           }
  664.           break;
  665.           
  666.         case CXM_COMMAND:
  667.           switch(msgid)
  668.           {
  669.             case CXCMD_APPEAR:    DoOpenWindow();     break;
  670.             case CXCMD_DISAPPEAR: DoCloseWindow();    break;
  671.             case CXCMD_DISABLE:   DisableCommodity(); break;
  672.             case CXCMD_ENABLE:    EnableCommodity();  break;
  673.             case CXCMD_KILL:      keepGoing = FALSE;  break;
  674.             case CXCMD_UNIQUE:    DoOpenWindow();     break;
  675.           }
  676.           break;
  677.       }
  678.     }
  679.  
  680.     /* handle incoming InputEvent messages from our custom CxObject */
  681.     {
  682.       BOOL BSent = FALSE;
  683.  
  684.       while(msg = (struct Message *)GetMsg(event_mp))
  685.       {
  686.         if ((session)&&(BConnectOkay))
  687.         {
  688.           struct InputEvent * ie = (struct InputEvent *) (((UBYTE *)msg)+sizeof(struct Message));
  689.       
  690.           /* Send a copy of the Input Event to our buddy */
  691.           if (QStreamOp(session, "e", ie, sizeof(struct InputEvent))) BSent = TRUE;
  692.         }
  693.         FreeMem(msg, msg->mn_Length);
  694.       }
  695.       if (BSent) 
  696.       { 
  697.         QGo(session, 0L);
  698.         if (BXmitCue) ToggleLED();
  699.       }
  700.     }
  701.  
  702.     if (session)
  703.     {
  704.       struct QMessage * qmsg;
  705.       
  706.       while(qmsg = (struct QMessage *)GetMsg(session->qMsgPort))
  707.       { 
  708.         if (qmsg->qm_Status == QERROR_NO_ERROR)
  709.         {
  710.           if (qmsg->qm_ID == 0) 
  711.           {
  712.             char temp[300];
  713.             char * t = qmsg->qm_Path, * u;
  714.  
  715.                  if (t == NULL) t = "(unknown)";
  716.             else if ((*t)&&(u = strchr(t+1, '/'))) t = u+1;
  717.             
  718.             strncpy(temp, "Connected: [", sizeof(temp));
  719.             strncat(temp, t, sizeof(temp));
  720.             strncat(temp, "]", sizeof(temp));
  721.             StatMsg(temp);
  722.  
  723.             BConnectOkay = TRUE;
  724.             BGUINeedsUpdate = TRUE;
  725.           }
  726.           else
  727.           {
  728.             if (qmsg->qm_DataLen == sizeof(struct InputEvent))
  729.             { 
  730.               struct InputEvent * ie = (struct InputEvent *)qmsg->qm_Data;
  731.               if ((BEnabled)&&(BXmitting == FALSE)) AddIEvents(ie);  /* Don't generate events from incoming data if we are xmitting events... we don't want a feedback loop! */
  732.             }
  733.             else printf("Error, bad data size (%i != %i)\n",qmsg->qm_DataLen, sizeof(struct InputEvent));
  734.           }
  735.         }
  736.         else
  737.         {
  738.           FreeQMessage(session, qmsg);  /* Gotta free this NOW!  Before the session is gone */
  739.           Accept();  /* Will disconnect and put up a passive session again... */
  740.           break;  /* Can't evaluate while() condition again!  session is dangling! */
  741.         }
  742.         FreeQMessage(session, qmsg);
  743.       }
  744.     }
  745.     
  746.     if (sigrcvd & SIGBREAKF_CTRL_C) {printf("CTRL-C detected.\n"); keepGoing = FALSE;}
  747.     if (sigrcvd & SIGBREAKF_CTRL_D) DisableCommodity();
  748.     if (sigrcvd & SIGBREAKF_CTRL_E) EnableCommodity();
  749.     if (sigrcvd & SIGBREAKF_CTRL_F) DoOpenWindow();
  750.  
  751.     if (BGUINeedsUpdate) UpdateGUIFromState(); 
  752.   }
  753.   
  754.   if (session) 
  755.   {
  756.     QFreeSession(session);
  757.     session = NULL;
  758.   }
  759.   
  760. }
  761.  
  762. __geta4 void CxFunction(register CxMsg * cxm, CxObj * co)
  763. {
  764.   struct InputEvent * ie;
  765.   
  766.   ie = (struct InputEvent *)CxMsgData(cxm);
  767.  
  768.   if ((ie->ie_Class == IECLASS_RAWKEY)     ||
  769.       (ie->ie_Class == IECLASS_RAWMOUSE)   ||
  770.       (ie->ie_Class == IECLASS_POINTERPOS)) 
  771.   {
  772.      /* Send a message containing a copy of this InputEvent to our program for transmission */
  773.      int bufLen = sizeof(struct Message)+sizeof(struct InputEvent);
  774.      struct Message * msg = (struct Message *)AllocMem(bufLen, MEMF_PUBLIC | MEMF_CLEAR);
  775.        
  776.      if (msg)
  777.      {
  778.        msg->mn_Node.ln_Type = NT_MESSAGE;
  779.        msg->mn_Length       = bufLen;
  780.        msg->mn_ReplyPort    = NULL;   /* No reply needed; we'll just free it */
  781.        memcpy(((UBYTE *)msg)+sizeof(struct Message), ie, sizeof(struct InputEvent));
  782.        PutMsg(event_mp, msg);
  783.      }
  784.   }
  785. }